package cn.com.dhcc.turbo.core;

import cn.com.dhcc.app.core.exception.ServiceException;
import cn.com.dhcc.turbo.entity.registry.NodeInfo;
import cn.com.dhcc.turbo.service.exch.DistributedNodeInfoService;

public class RmiGet {

		public static void main(String[] args) throws ServiceException, InterruptedException {
			/*String queue="SQ_000000101_TO_020000101_SQL_DATA_LOG";
					System.out.println(queue.split("_TO_")[1].substring(0,6));
					
					System.out.println(new SendQue("sq_12").getSendQueName().getValue());*/
			DistributedNodeInfoService service=new DistributedNodeInfoService();
			for (int i = 0; i < 100; i++) {
				System.out.println("***第"+(i+1)+"次调用******");
				NodeInfo n=new NodeInfo();
				n.setInstallUrl("http://10.2.65.81:8080/turbo");
				System.out.println(service.getRmi(n));
			}
		}
}
